package com.kafka.controller;

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @author God.Jhon.Black
 * @date 2023-02-06
 */
@RestController
public class TestController {

    @Resource
    private KafkaTemplate kafkaTemplate;

    @RequestMapping("/test")
    public void test(){
        kafkaTemplate.send("t-cityos-dright-user-role-change","111");
    }
}
